//package com.ask.service.utilService;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Service;
//
//@Service
//@Slf4j
//public class KafkaConsumerService {
//    @KafkaListener(topics = "title", groupId = "my-group")
//    public void listen(String message) {
//        System.out.println("Received message：" + message);
//        log.info("receive msg:{}", message);
//    }
//}
